package com.example.mq.common;

import lombok.Data;

import java.io.Serializable;

@Data
public class BasicConsumeArguments extends BasicArguments implements Serializable {
    private String consumerTag;
    private String queueName;
    private boolean autoAck;

    // 本类对应的 basicConsume 方法中, 还有一个参数: 回调函数
    // 但是该回调函数, 不能通过网络传输
    // 站在 broker server 角度, 针对消息的处理回调是统一的 (把消息返回给客户端)
    // 客户端收到消息之后, 再往客户端这里执行一个用户自定义的回调就可以了
    // 因此, 客户端也不需要把自身的回调告诉服务器了
    // 因此本类就不需要 consumer 成员了
}
